from concurrent.futures import ThreadPoolExecutor, as_completed


class ThreadPool:
    executor = any

    def __init__(self):
        self.executor = ThreadPoolExecutor(max_workers=16, thread_name_prefix="my_thread")


threadPool = ThreadPool()

